<?php

namespace app\queue;

use Webman\RedisQueue\Consumer;

class DemoQueue implements Consumer
{
    // 消费队列实例
    public $queue = 'demo_queue';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {

        var_export($data);
    }
}